e06c26b7a3a0bb31273225f3c41004ba5992fa70,contrib/stress/src/org/apache/cassandra/contrib/stress/operations/IndexedRangeSlicer.java,IndexedRangeSlicer,run,#,37

Before Change


                List<KeySlice> results = null;
                long start = System.currentTimeMillis();

                try
                {
                    results = client.get_indexed_slices(parent, clause, predicate, session.getConsistencyLevel());

                    if (results.size() == 0)
                    {
                        System.err.printf("No indexed values from offset received: %s%n", startOffset);

                        if (!session.ignoreErrors())
                            break;
                    }
                }
                catch (Exception e)
                {
                    System.err.printf("Error on get_indexed_slices call for offset  %s - %s%n", startOffset, getExceptionMessage(e));

                    if (!session.ignoreErrors())
                        return;

After Change


                List<KeySlice> results = null;
                long start = System.currentTimeMillis();

                boolean success = false;
                String exceptionMessage = null;

                for (int t = 0; t < session.getRetryTimes(); t++)
                {
                    if (success)
                        break;

                    try
                    {
                        results = client.get_indexed_slices(parent, clause, predicate, session.getConsistencyLevel());
                        success = (results.size() != 0);
                    }
                    catch (Exception e)
                    {
                        exceptionMessage = getExceptionMessage(e);
                        success = false;
                    }
                }

                if (!success)
                {
                    System.err.printf("Thread [%d] retried %d times - error on calling get_indexed_slices for offset %s %s%n",
                                                                                              index,
                                                                                              session.getRetryTimes(),
                                                                                              startOffset,
                                                                                              (exceptionMessage == null) ? "" : "(" + exceptionMessage + ")");

                    if (!session.ignoreErrors())
                        return;